package com.qingcloud.df.executor.queue;

import com.qingcloud.df.executor.enums.ComponentCommunicationEnum;
import com.qingcloud.df.sdk.component.message.ComponentValue;
import lombok.Data;

/**
 * 组件消息
 *
 * @author yangfan
 * @date 2022/1/20 9:46
 */
@Data
public class ComponentMessage {


    /**
     * 实例id
     */
    private Integer instanceId;

    private String env = "dev";
    /**
     * 发送实例id
     */
    private Integer sendInstanceId;

    /**
     * 通信方式
     * @see ComponentCommunicationEnum
     */
    public String communicationType;


    public String messageFrom;
    /**
     * 主题名称
     */
    private String topic;

    /**
     * 数据消费次数
     */
    private Integer consumeCount = 0;

    /**
     * 组件消息
     */
    private ComponentValue componentValue;
}
